package com.twjitm.core.common.kafka;/** * @author twjitm - [Created on 2018-09-04 21:31] * @company https://github.com/twjitm/ * @jdk java version "1.8.0_77" */public abstract class AbstractKafkaPushTask {    private KafkaTaskType taskType;    public Object value;    public AbstractKafkaPushTask(KafkaTaskType taskType) {        this.taskType = taskType;    }    public KafkaTaskType getTaskType() {        return taskType;    }    public Object getValue() {        return value;    }    /**     * 需要将消息值保存到这里面，值如何获得由子类自己实心     *     * @param value     */    public abstract void setValue(Object value);}